Processing Multiple Signals with input_variants()

from sigexec import Graph
from sigexec.blocks import RangeCompress, DopplerCompress
from sigexec.core.data import GraphData

# Load or generate different signals
signal_dataset_a = load_signal("dataset_a.bin")
signal_dataset_b = load_signal("dataset_b.bin")  
signal_dataset_c = load_signal("dataset_c.bin")

# Process all three through the same graph
results = (Graph()
    .input_variants([signal_dataset_a, signal_dataset_b, signal_dataset_c],
                   names=['Dataset A', 'Dataset B', 'Dataset C'])
    .add(RangeCompress(window='hamming'))
    .add(DopplerCompress(window='hann'))
    .run()
)

# Results contains one (params, result) tuple for each input signal
for params, result in results:
    dataset_name = params['variant'][0]
    print(f"{dataset_name}: peak at {find_peak(result)}")

from sigexec import Graph
from sigexec.core.data import GraphData
import numpy as np

# Create a loader factory - data is loaded only when the variant executes
def make_loader(filename):
    def load(_):
        data = np.load(filename)  # Loaded on demand, not upfront
        return GraphData(data, metadata={'sample_rate': 20e6})
    return load

# Process multiple files through the same graph
# Each file is loaded only when needed, one at a time
results = (Graph()
    .variants(make_loader, 
              ['dataset_a.npy', 'dataset_b.npy', 'dataset_c.npy'],
              names=['Dataset A', 'Dataset B', 'Dataset C'])
    .add(StackPulses())
    .add(RangeCompress(window='hamming'))
    .add(DopplerCompress(window='hann'))
    .run()
)

# Results contains one (params, result) tuple for each file
for params, result in results:
    dataset_name = params['variant'][0]
    print(f"Processed {dataset_name}")

from sigexec import Graph

# Loader factory
def make_loader(filename):
    def load(_):
        data = np.load(filename)
        return GraphData(data, metadata={'sample_rate': 20e6})
    return load

# 3 files × 2 range windows × 2 Doppler windows = 12 total combinations
# But only one file is in memory at a time!
results = (Graph()
    .variants(make_loader, 
              ['sig_a.npy', 'sig_b.npy', 'sig_c.npy'],
              names=['Signal A', 'Signal B', 'Signal C'])
    .add(StackPulses())
    .variants(lambda w: RangeCompress(window=w), 
              ['hamming', 'blackman'],
              names=['Hamming', 'Blackman'])
    .variants(lambda w: DopplerCompress(window=w), 
              ['hann', 'hamming'],
              names=['Hann', 'Hamming'])
    .run()
)

# Access all three levels of variants
for params, result in results:
    signal_name = params['variant'][0]
    range_window = params['variant'][1]
    doppler_window = params['variant'][2]
    print(f"{signal_name} + Range:{range_window} + Doppler:{doppler_window}")